package com.ruoyi.constant;

/**
 * @description:
 * @author: Sunhongchen
 * @date: 2021-12-01
 */
public interface MQGroupConstants {
    /**
     * consumer 最大线程数
     */
    int consumeThreadMax = 8;

    /**
     * Topic组Id
     */
    String EDU_TOPIC_GROUP_ID = "TAXI_MANAGEMENT_TOPIC_GROUP";

    //String EDU_TOPIC_GROUP_ID = "test-group";

    /**
     * 出租车实时数据topic
     */
    String TOPIC = "taxi_real_time_topic";
    //String TOPIC = "YOUR_TOPIC";
}
